package cn.jbooter.mq.autoconfigure.rocketmq.coms;

import org.apache.rocketmq.common.message.MessageExt;

import cn.jbooter.mq.autoconfigure.rocketmq.properties.RocketConsumerInitInfo;


/**
 * consumer基类
 * @author HeJian
 *
 */
public interface IRocketConsumer {

	/**
	 * consumer的初始化
	 */
	public void init(RocketConsumerInitInfo init) throws Exception;
	
	/**
	 * consumer的销毁
	 */
	public void destroy()throws Exception;
	
	/**
	 * 业务的消息处理,push consumer的消息处理失败会重新再次消费,故业务处理注意幂等处理
	 * 
	 * @param message 消息
	 * @return true:消息处理成功 false:消息处理失败
	 */
	public boolean process(MessageExt message);
	
	
	
	
}
